#include "pch.h"
#include "QueueProvider.h"




QueueProvider::QueueProvider()
	: m_reader(m_queue.reader<boostext::read_unbuffered>())
	, m_writer(m_queue.writer<boostext::write_unbuffered>())
{}
///////////////////////////////////////////////////////////////////////////////////////////////////

QueueProvider::~QueueProvider()
{}
///////////////////////////////////////////////////////////////////////////////////////////////////




Reply::Opt QueueProvider::next()
{
	return m_reader.pop();
}
///////////////////////////////////////////////////////////////////////////////////////////////////

void QueueProvider::insert(const Reply& reply)
{
	m_writer.push(reply);
}
///////////////////////////////////////////////////////////////////////////////////////////////////
